package com.xian.im.message.producer;

import com.xian.im.common.constant.CommandConstant;
import com.xian.im.common.model.session.SessionUser;
import com.xian.im.message.model.QueueMsg;
import com.xian.im.message.queue.MessageLoginQueue;
import io.netty.channel.ChannelHandlerContext;

/**
 * @program: xian-im-server
 * @description:
 * @author: liru.xian
 * @create: 2021-03-01 10:15
 **/
public class LoginProducer implements MessageProducer {
    /**
     *
     */
    @Override
    public void doHandler(QueueMsg message, SessionUser session, ChannelHandlerContext ctx) {
        MessageLoginQueue.put(message);
    }

    /**
     * @return
     */
    @Override
    public Integer getType() {
        return CommandConstant.LOGIN_CMD;
    }
}
